package com.qianmi.ms.starter.rocketmq.constants;

public class DefaultRocketMQListenerContainerConstants {
    public static final String PROP_NAMESERVER = "namespace";
    public static final String PROP_TOPIC = "topic";
    public static final String PROP_CONSUMER_GROUP = "consumer_group";
    public static final String PROP_CONSUME_MODE = "consume_mode";
    public static final String PROP_CONSUME_THREAD_MAX = "consume_thread_max";
    public static final String PROP_ROCKETMQ_LISTENER = "rocketmq_listener";
    public static final String PROP_MESSAGE_MODEL = "message_model";
    public static final String PROP_SELECTOR_EXPRESS = "selector_express";
    public static final String PROP_SELECTOR_TYPE = "selector_type";
    public static final String PROP_PULL_THRESHOLD_FOR_TOPIC = "pull_threshold_for_topic";
    public static final String PROP_PULL_THRESHOLD_SIZE_FOR_TOPIC = "pull_threshold_size_for_topic";
    public static final String PROP_OBJECT_MAPPER = "object_mapper";
    public static final String METHOD_DESTROY = "method_destroy";
}